const DB = require('./db')
const mysql = require('mysql')

module.exports =  function(sqlsyntax,params){
    return new Promise((resolve,reject)=>{
        const sql = mysql.createPool(DB)
        sql.getConnection((sqlerr,conntion)=>{
            if(sqlerr){
                return reject(sqlerr);
                
            }else{
                /* 判断是否有请求*/
            params=params||[];

            /* 按需切换SQL语句 */
            switch (sqlsyntax) {
                case undefined:
                    sqlsyntax='SELECT * FROM user'
                    break;
                case 'login':
                    sqlsyntax='SELECT * FROM user where username=? and password=?'
                    break;
                case 'goods':
                    sqlsyntax='select * from backup_goods'
                    break;
                default:
                    sqlsyntax=sqlsyntax
                    break;
            }
            
            conntion.query(sqlsyntax,params,(err,data)=>{
                 if(err){
                    return reject(err,'这是链接错误');
                 }else{
                     
                    resolve(data) 
                 }
             })
            }
            sql.end()
        })
        
 })
    
}


    /* 测试Sql */
//    const sql = mysql.createPool(DB)
//    sql.getConnection((sqlerr,conntion)=>{
//        if(sqlerr){
//            console.log(sqlerr);
//            return
//        }else{
//         conntion.query('select * from user',(err,data)=>{
//             if(err){
//                 console.log(err,'这是链接错误');
//             }else{
//                 console.log(data);
//                 res.send(data)
//             }
//         })
//        }
//    })
 
 
 
     